package com.zmn.oms.task.kafka.process;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.scheduling.annotation.Async;

/**
 * 类描述：dts 数据消费
 * @author lujia
 * @date 2019/8/15 20:22
 */
public interface RecordProcessService {

    /**
     * 多线程消费处理数据
     * @param record
     */
    @Async
    void process(ConsumerRecord<String, byte[]> record);
}
